package com.test.rxjavaImp;

public interface Observer<T> {

    void onSubScribe();

    void onNext(T t);

    void onComplete();

    void onError(Throwable throwable);

}
